package com.huahua.bigdata.sparksql;

import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;

public class SparkSQL06_Source_Parquet {
    public static void main(String[] args) {
        final SparkSession sparkSession = SparkSession
                .builder()
                .master("local[*]")
                .appName("SparkSQL")
                .getOrCreate();

        Dataset<Row> parquet = sparkSession.read().parquet("data/user.parquet");
        //csv.write().parquet("output");
        parquet.show();

        sparkSession.close();
    }
}
